package com.xinnet.mms.utils;

import javax.jms.JMSException;  
import javax.jms.Message;  
import javax.jms.Session;  
  
import org.springframework.jms.core.MessageCreator;  
  

public class MyMessageCreator implements MessageCreator {  
    public String msg = "";
    @Override  
    public Message createMessage(Session paramSession) throws JMSException {  
        System.out.println("Send Msg = " + msg);  
        return paramSession.createTextMessage(msg);  
    }  
}  